package concurent

import (
	"fmt"
	"io/ioutil"
	"log"
	"math/rand"
	"net/http"
	"time"
)

func show(msg string) {
	fmt.Println("======")
	for i := 0; i < 5; i++ {
		fmt.Printf("msg: %v\n", msg)
		time.Sleep(time.Millisecond * 100)
	}
}

func Go_f1() {
	go show("go")
	time.Sleep(time.Millisecond * 100)
	fmt.Println("end")
}

func responseSize(url string) {
	fmt.Println("step1:", url)
	r, err := http.Get(url)
	if err != nil {
		// Fatal 致命错误
		log.Fatal(err)
		return
	}
	fmt.Println("step2:", url)
	defer r.Body.Close()

	fmt.Println("step3:", url)
	b, err2 := ioutil.ReadAll(r.Body)
	if err2 != nil {
		log.Fatal(err2)
		return
	}
	fmt.Println("step4:", len(b))
}

func Go_f2() {
	go responseSize("https://www.baidu.com")
	go responseSize("https://www.duoke360.com")
	time.Sleep(time.Second * 10)
}

func Go_f3() {
	defer close(valueChan)
	go send()
	fmt.Println("wait...")
	// 阻塞  直到接收到数据为止
	value := <-valueChan
	fmt.Printf("receive value: %v\n", value)
	fmt.Println("end...")
}

// 协程间数据共享
/*
	无缓冲通道用于执行 goroutine 之间的同步通信（阻塞  有数据就不能再放数据进去），而缓冲通道用于执行异步通信（可以放入多个数据）。
	无缓冲通道保证在发送和接收发生的瞬间执行两个 goroutine 之间的交换。缓冲通道没有这样的保证。

	通道的发送和接收特性
对于同一个通道，发送操作之间是互斥的，接收操作之间也是互斥的。
发送操作和接收操作中对元素值的处理都是不可分割的。
发送操作在完全完成之前会被阻塞。接收操作也是如此。
*/
var valueChan = make(chan int)

func send() {
	rand.Seed(time.Now().UnixNano())
	value := rand.Intn(10)
	fmt.Printf("send value: %v\n", value)
	time.Sleep(time.Second * 3)
	valueChan <- value
}
